package app.kafka.produce;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

/**
 * 使用springboot-kafka
 * 
 * @author lfy.xys
 * @date 2018年5月3日
 *
 */
@Component
public class HTBYKafkaProducer {
	@Autowired
	private KafkaTemplate<String, String> kafkaTemplate;

	/**
	 * 测试发送消息方法
	 * 
	 * @author lfy.xys
	 * @date 2018年5月3日
	 *
	 */
	public void send() {
		send("test","", "111test");
	}

	/**
	 * 发送消息方法
	 * 
	 * @author lfy.xys
	 * @date 2018年5月3日
	 *
	 * @param topic
	 * @param msg
	 */
	public void send(String topic, String msg) {
		send(topic, "", msg);
	}

	/**
	 * 发送消息方法
	 * 
	 * @author lfy.xys
	 * @date 2018年5月3日
	 *
	 * @param topic
	 * @param key
	 * @param msg
	 */
	public void send(String topic, String key, String msg) {
		kafkaTemplate.send(topic, key, msg);
	}
}
